mod gtl;
mod mq;
use tokio::sync::mpsc;
use crate::{gtl::tcpserver};
use crate::mq::broker;

#[tokio::main]
async fn main(){
    let (tx, mut rx) = mpsc::channel(10);
    _ = tx.send(10).await;

    {
        let st = broker::get_broker();
        let mut s = st.lock().await;
        s.start();
    }

    tcpserver::TcpServer::new("0.0.0.0:60000".to_string(),false).start().await;

    while let Some(_msg) = rx.recv().await {
        
    } 
}

